package com.dcloud.streamweb.core.jobserver;


import com.dcloud.streamweb.taskmanage.entity.dto.JobConfigDTO;
import com.dcloud.streamweb.taskmanage.entity.dto.JobRunParamDTO;

/**
 * @author zhuhuipei
 * @Description:
 * @date 2021/3/28
 * @time 10:01
 */
public interface JobBaseServiceAO {

  /**
   * 提交任务前校验数据
   *
   * @author zhuhuipei
   * @date 2021/3/28
   * @time 10:12
   */
  void checkStart(JobConfigDTO jobConfigDTO);


  JobRunParamDTO writeSqlToFile(JobConfigDTO jobConfigDTO);

  Long insertJobRunLog(JobConfigDTO jobConfigDTO, String userName);

  void aSyncExecJob(JobRunParamDTO jobRunParamDTO, JobConfigDTO jobConfigDTO, Long jobRunLogId, String savepointPath);

    void checkSavepoint(JobConfigDTO jobConfigDTO);
}
